#!/bin/bash
# 脚本目录
file_dir="/root/dwd/"
# 日志目录
log_dir="/root/dwd/log/"
# 获取ETL时间
dt=`date -d '-1 day' +"%Y-%m-%d"`

nohup hive -hivevar dt="$dt" -f "$file_dir"dwd.dim_aml_account_inc.sql      > "${log_dir}dwd.dim_aml_account_inc.sql"/"$dt".log &
nohup hive -hivevar dt="$dt" -f "$file_dir"dwd.dim_aml_customer_full.sql    > "${log_dir}dwd.dim_aml_customer_full.sql"/"$dt".log &
nohup hive -hivevar dt="$dt" -f "$file_dir"dwd.dim_aml_rule_full.sql        > "${log_dir}dwd.dim_aml_rule_full.sql"/"$dt".log &
nohup hive -hivevar dt="$dt" -f "$file_dir"dwd.dim_aml_watchlist_inc.sql    > "${log_dir}dwd.dim_aml_watchlist_inc.sql"/"$dt".log &
nohup hive -hivevar dt="$dt" -f "$file_dir"dwd.fact_aml_alert_inc.sql       > "${log_dir}dwd.fact_aml_alert_inc.sql"/"$dt".log &
nohup hive -hivevar dt="$dt" -f "$file_dir"dwd.fact_aml_screening_inc.sql   > "${log_dir}dwd.fact_aml_screening_inc.sql"/"$dt".log &
nohup hive -hivevar dt="$dt" -f "$file_dir"dwd.fact_aml_str_report_inc.sql  > "${log_dir}dwd.fact_aml_str_report_inc.sql"/"$dt".log &
nohup hive -hivevar dt="$dt" -f "$file_dir"dwd.fact_aml_transaction_inc.sql > "${log_dir}dwd.fact_aml_transaction_inc.sql"/"$dt".log &

# 清理两天前的日志文件
rm -rf `find /root/dwd/log -mtime 2`

wait
echo "【DWD】所有任务执行完成。"

echo "【DWS】开始执行汇总层任务..."

nohup hive -hivevar dt='$dt' -f "$file_dir"dws_inc_aml_customer_risk_profile.sql>"$log_dir""dws_inc_aml_customer_risk_profile.sql"/"$dt".log &
nohup hive -hivevar dt='$dt' -f "$file_dir"dws_inc_aml_risk_dashboard.sql>"$log_dir""dws_inc_aml_risk_dashboard.sql"/"$dt".log &
nohup hive -hivevar dt='$dt' -f "$file_dir"dws_inc_aml_transaction_behavior.sql>"$log_dir""dws_inc_aml_transaction_behavior.sql"/"$dt".log &